package com.shujia.MR.output;

import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.mapreduce.*;
import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;

import java.io.IOException;

public class MyOutputFormat extends FileOutputFormat<Student, NullWritable> {

    /**
     * 将学生成绩进行划分，大于450分存放至一个文件中，其他存放至另外一个文件中
     * 由于当前getRecordWriter要求返回一个RecordWriter并且所有写的逻辑都在RecordWriter中实现
     *      所以需要自定义一个RecordWriter子类
     *
     */
    @Override
    public RecordWriter<Student, NullWritable> getRecordWriter(TaskAttemptContext context) throws IOException, InterruptedException {

        return new MyRecordWriter(context.getConfiguration());
    }

}
